package s.c.helper;

import lombok.extern.slf4j.Slf4j;
import s.c.server.WebSocketServer;

import javax.websocket.Session;
import java.io.IOException;
import java.util.List;

/**
 * @Author: SYL
 * @Date: 2024/7/25
 */
@Slf4j
public class SendHelper {

    /**
     * 发送文字给其他用户
     *
     * @param message 发送信息
     * @param session 目的session
     */
    public static void sendToPersonStr(String message, Session session) {
        try {
            session.getBasicRemote().sendText(message);
        } catch (IOException e) {
            e.printStackTrace();
            log.error("send message error: {}", e.getMessage());
        }
    }

    /**
     * 发送文字给群组
     *
     * @param message          发送信息
     * @param webSocketServers 目的群组
     */
    public static void sendToGroupStr(String message, List<WebSocketServer> webSocketServers) {
        webSocketServers.forEach(ws -> sendToPersonStr(message, ws.getSession()));
    }

}
